package cn.arikeky.oneway;

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.Message;

import java.nio.charset.StandardCharsets;

public class SyncProducer {
	public static void main(String[] args) throws Exception {
    	// 实例化消息生产者Producer
        DefaultMQProducer producer = new DefaultMQProducer("oneway_group_name");
    	// 设置NameServer的地址
    	producer.setNamesrvAddr("localhost:9876");
    	// 启动Producer实例
        producer.start();
        // 循环发送
    	for (int i = 0; i < 20; i++) {
    	    // 创建消息，并指定Topic，Tag和消息体
    	    Message msg = new Message("oneway-Topic",
        	"oneway_Tag",
        	"单向消息------".getBytes(StandardCharsets.UTF_8)
        	);
        	// 发送同步消息到一个Broker
            producer.sendOneway(msg);
			System.out.println("发送成功");
    	}
    	// 如果不再发送消息，关闭Producer实例。
    	producer.shutdown();
    }
}